from __future__ import absolute_import, unicode_literals
import os
from celery import Celery

# 设置默认的 Celery 应用程序模块（根据 Django 项目的名称）
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'recommand_demo.settings')

# 创建 Celery 应用程序实例
celery_app = Celery('recommand_demo')

# 加载配置
celery_app.config_from_object('django.conf:settings', namespace='CELERY')

# 自动发现异步任务（即在 Django 应用程序中定义的任务）
celery_app.autodiscover_tasks()
